博客中代码地址：https://github.com/farliu/farpc.git
dubbo架构

上一章我们了解了dubbo最核心的一块，就是数据传输和调用，我们知道真正调用的原理。以及更早的时候还介绍注册中心的实现，用来管理每一个服务提供者的信息，供消费者路由到相关的服务提供者上去。这个过程细想，做的事情还挺多的。dubbo不可能为每一个服务都去实现从注册中心拿到提供者，负载均衡后调用指定的提供者，而且这个给框架使用者去实现也不合适。那么dubbo解决这一问题的方案就是动态代理。

在更早之前也有提到过这一块,感兴趣可以先了解:谈谈mybatis、dubbo基础原理

这章基本内容就是为提供的api接口,生成代理类,在代理类中实现上述所说的,调用注册中心、负载均衡、远程调用等等

项目结构介绍

项目结构
本节涉及博客中代码的两个module，farpc-rpc（远程调用）、farpc-demo。

代理实现

ConsumerProxy需要做的事情,上面讲的很详细了,这里罗列一下.

  1. 生成代理类
  2. 调用注册中心
  3. 远程调用
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    public class ConsumerProxy {
        private static final Logger logger = LoggerFactory.getLogger(ConsumerProxy.class);

        public static <T> T create(final Class<T> interfaceClass) {
            Object o = Proxy.newProxyInstance(interfaceClass.getClassLoader(), new Class[]{interfaceClass}
                    , new InvocationHandler() {
                        public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {

                            // 封装调用参数
                            RequestDTO requestDTO = new RequestDTO();
                            requestDTO.setClassName(method.getDeclaringClass().getName());
                            requestDTO.setMethodName(method.getName());
                            requestDTO.setTypes(method.getParameterTypes());
                            requestDTO.setParams(args);

                            // 获取服务提供者
                            IRegistrar registrar = RegistrarFactory.getRegistrar();
                            String service = interfaceClass.getName();
                            String serivceAddress = registrar.discover(service);

                            // 调用上一章写的远程调用
                            Object result = RpcFactory.getConsumerService().execute(serivceAddress, requestDTO);
                            return result;
                        }
                    });
            return (T) o;
        }
    }

由于这里实现只是rpc调用,没有完整的生命周期,也就是说在消费者调用这里还可以优化.比如像dubbo一样在项目启动时去解析xml或者扫描Reference注解.这一块是本系列博客所缺少的.

测试

在启动服务端后,我们再测试直接调用接口的代理对象,对于扫描Reference注解,然后像spring那样注入到具体对象中,也可以再做更深的了解.

1
2
3
4
5
6
@Test
public void consumerTest(){
    IWelcome welcome = ConsumerProxy.create(IWelcome.class);
    String far = welcome.greet("far");
    System.out.println(far);
}

至于上面的运行结果,也肯定是令人满意的,期待各位自己测试.